package com.zsy.filink.basic;

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.tuple.Tuple2;

/**
 * @Author: Zhou ShiYang
 * @Description:
 * @Date:Create：in 2021/7/29 0:06
 **/
public class PKMapFunction implements MapFunction<String, Tuple2<String, Integer>> {
    @Override
    public Tuple2<String, Integer> map(String s) throws Exception {
        return new Tuple2<>(s, 1);
    }
}
